package com.boot.cluster.worker.runner;

import com.boot.cluster.worker.bean.TaskResponse;

import java.io.Serializable;
import java.util.List;

public interface ClusterComputeTask<T, R> extends Serializable {


    void map(T t) throws Exception;

    R reduce(List<TaskResponse> responses) throws Exception;


}
